package cn.money.transport.mq;

import cn.monkey.transport.core.Outbound;
import reactor.core.publisher.Mono;

import java.util.concurrent.Flow;

public interface MqOutbound extends Outbound {
    String topic();

    Mono<Void> close();

}
